package com.roy.kafka.trident;

import org.apache.storm.topology.TopologyBuilder;

public class KafkaProducerTopology {

    public static void main(String[] args) {
        TopologyBuilder builder = new TopologyBuilder();
        builder.setSpout("spout",new RandomSentenceSpout(),2);

    }
}
